package com.sikaryofficial.backend.message.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * input 消费者定义
 *
 *
 * @Description: MySink
 */
public interface MQConsumer {
    String BINDINGS_ACTIVITY_PURCHASE_INPUT = "activity-purchase-input";

    String BINDINGS_SCAN_REGISTER_INPUT = "scan-register-input";

    String BINDINGS_LOTTERY_INPUT = "lottery-input";

    String BINDINGS_ACTIVITY_RESULT_USERINFO_INPUT = "activity-result-userinfo-input";
    @Input(BINDINGS_ACTIVITY_RESULT_USERINFO_INPUT)
    SubscribableChannel activityResultModify();

    @Input(BINDINGS_ACTIVITY_PURCHASE_INPUT)
    SubscribableChannel attendInput();

    @Input(BINDINGS_SCAN_REGISTER_INPUT)
    SubscribableChannel scanRegisterInput();

    @Input(BINDINGS_LOTTERY_INPUT)
    SubscribableChannel lotteryInput();
}
